package com.sanfu.etl.service;

import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.hadoop.hbase.client.Delete;

import java.util.List;

// *********************
// ** @Date: 2021-06-29
// ** @Author: Camemax
// ** @Description: 定义执行HBase的相关CRUD操作方法
// *********************
public interface FlinkHBaseService
{
//    void close(); // 关闭连接
//    void queryScan(); // 根据条件过滤查询
//    void get() ; // 根据rowKey查询
//    <T> void save(T ... objs); // 保存pojo对象
//    <T> void save(String tableName, T ... objs); // 根据tableName保存
//    <T> void delete(T obj, String... rowkeys); // 删除操作
//    void deleteInBatch(List<Delete> target, String tableName); // 批量删除
}
